
create external table jms_dm.dm_trunk_flow_direction
(
    shipment_no          string comment ' 任务号code',
    shipment_name        string comment ' 任务号名',
    line_part_name        string comment ' 线路段名称',
    start_site_code      string comment ' 始发中心',
    start_site_name      string comment ' 始发中心',
    start_fina_code      string comment ' 始发代理区',
    start_fina_name      string comment ' 始发代理区',
    end_site_code        string comment ' 目的中心',
    end_site_name        string comment ' 目的中心',
    end_fina_code        string comment ' 目的代理区',
    end_fina_name        string comment ' 目的代理区',
    planned_arrival_time timestamp comment '计划到车时间',
    actual_arrival_time timestamp comment '实际到车时间',
    package_cnt          int comment '包件',
    package_in_cnt       int comment '包内票数',
    single_cnt           int comment '单件（包外票数）',
    all_sigle            int comment '总件数 = 包件 + 单件',
    all_piece            int comment '总票数 = 包内票 + 单件',
    local_package_cnt    int comment '本地件_包件',
    local_package_in_cnt int comment '本地件_包内票数',
    local_single_cnt     int comment '本地件_单件（包外票数）',
    local_all_sigle      int comment '本地件_总件数 = 包件 + 单件',
    local_all_piece      int comment '本地件_总票数 = 包内票数 + 单件',
    cross_package_cnt    int comment '中转件_包件',
    cross_package_in_cnt int comment '中转件_包内票数',
    cross_single_cnt     int comment '中转件_单件（包外票数）',
    cross_all_sigle      int comment '中转件_总件数 = 包件 + 单件',
    cross_all_piece      int comment '中转件_总票数 = 包内票数 + 单件',
    no_cross_center_cnt      int comment '未匹配到三段码票数',
    planned_date           date comment '规划发车日期'
) COMMENT '干线线路流向单票统计'
    PARTITIONED BY (dt STRING COMMENT '规划发车时间')
    STORED AS PARQUET
    LOCATION '/dw/hive/jms_dm.db/external/dm_trunk_flow_direction';


alter table  jms_dm.dm_trunk_flow_direction_cross set tblproperties ('external.table.purge'='true');
drop table  jms_dm.dm_trunk_flow_direction_cross ;

create external table jms_dm.dm_trunk_flow_direction_cross
(
    shipment_no          string comment ' 任务号code',
    shipment_name        string comment ' 任务号名',
    line_part_name        string comment ' 线路段名称',
    start_site_code      string comment ' 始发中心',
    start_site_name      string comment ' 始发中心',
    start_fina_code      string comment ' 始发代理区',
    start_fina_name      string comment ' 始发代理区',
    end_site_code        string comment ' 目的中心',
    end_site_name        string comment ' 目的中心',
    end_fina_code        string comment ' 目的代理区',
    end_fina_name        string comment ' 目的代理区',
    terminal_center_code string comment '中转件code 目的中心（三段对应中心）',
    terminal_center_name string comment ' 中转件 目的中心（三段对应中心）',
    planned_arrival_time timestamp comment '计划到车时间',
    actual_arrival_time timestamp comment '实际到车时间',
    cross_package_cnt    int comment '中转件_包件',
    cross_package_in_cnt int comment '中转件_包内票数',
    cross_single_cnt     int comment '中转件_单件（包外票数）',
    cross_all_sigle      int comment '中转件_总件数 = 包件 + 单件',
    cross_all_piece      int comment '中转件_总票数 = 包内票数 + 单件',
    planned_date           date comment '规划发车日期'
) COMMENT '干线线路中转件流向票量统计'
    PARTITIONED BY (dt STRING COMMENT '规划发车时间')
    STORED AS PARQUET
    LOCATION '/dw/hive/jms_dm.db/external/dm_trunk_flow_direction_cross';


